package com.codeduck.kafka;

import com.codeduck.pojo.TopicHandler;

import java.util.Properties;

/**
 * @author: <a href="mailto:codeduck@163.com">Codeduck</a>
 * @date: 2023/6/23
 */
public abstract class KafkaOperations <K, V>{

    public abstract void subscribe(Properties properties, TopicHandler topicHandler);
}
